package cn.iocoder.yudao.framework.mq.rocketmq.api.consumer.dto;


import cn.iocoder.yudao.framework.mq.rocketmq.api.base.BaseMessage;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.time.LocalDateTime;

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class MqErrorMessage extends BaseMessage {

    /**
     * 业务键，用于RocketMQ控制台查看消费情况
     */
    private Long mqKey;
    /**
     * 原件 名(原上传附件名)
     */
    private String source;
    /**
     * 发送时间
     */
    private LocalDateTime sendTime;
    /**
     * 重试次数，用于判断重试次数，超过重试次数发送异常警告
     */
    private Integer retryTimes;
    /**
     * 消息体
     */
    private String message;

}
